load('classpath:ext/nsq.js');

var nsq = new Nsq();
var sub = nsq.sub("127.0.0.1:4161", "test", "java", function (msg) {
    console.info("msg = " + util.toString(msg.getData()));
    // return true;
    // 表示消息处理失败了.
    // return false;
});

console.info("start...");
util.sleep(10000);
sub.close();